f14914d467829362a483e62e493e7a9b1ac919be,src/main/java/bazahe/httpproxy/ConnectProxyHandler.java,ConnectProxyHandler,handle,#Socket#Socket#String#String#HttpMessageListener#,100

Before Change


    private void handle(Socket serverSocket, Socket clientSocket, String protocol, String target,
                        @Nullable HttpMessageListener httpMessageListener) throws IOException {
        HttpInputStream srcInput = new HttpInputStream(new BufferedInputStream(serverSocket.getInputStream()));
        HttpOutputStream srcOutput = new HttpOutputStream(serverSocket.getOutputStream());
        HttpInputStream destInput = new HttpInputStream(new BufferedInputStream(clientSocket.getInputStream()));
        HttpOutputStream destOutput = new HttpOutputStream(clientSocket.getOutputStream());

        while (true) {

After Change


        HttpInputStream srcInput = new HttpInputStream(new BufferedInputStream(
                new ObservableInputStream(serverSocket.getInputStream(), clientSocket.getOutputStream())));
        HttpInputStream destInput = new HttpInputStream(new BufferedInputStream(
                new ObservableInputStream(clientSocket.getInputStream(), serverSocket.getOutputStream())));


        while (true) {